data class ExtractionInvocationRecord constructor(val id: ExtractionInvocationId, val outcome: ExtractionInvocationOutcome = ExtractionInvocationOutcome.IN_FLIGHT, val configuredService: String? = null, val startedAt: Instant? = null, val finishedAt: Instant? = null, val usage: ExtractionModelUsage? = null, val providerResponse: ExtractionProviderResponseFacts? = null)

One attempt at one model call: its identity, and what was observed about it.

ExtractionModelUsage

data class ExtractionModelUsage constructor(val inputTokens: Int? = null, val outputTokens: Int? = null, val totalTokens: Int? = null, val cachedInputTokens: Int? = null, val reasoningTokens: Int? = null)

Tokens a call actually consumed, as the provider reported them.

ExtractionOpaqueRef

sealed class ExtractionOpaqueRef

A bounded, host-minted token that names something about a run without describing it.

ExtractionPersonalizationRef

class ExtractionPersonalizationRef(val token: String) : ExtractionOpaqueRef

Names the personalization state in force, without holding any of it.

ExtractionPerspective

enum ExtractionPerspective : Enum<ExtractionPerspective>

Controls whose perspective propositions are extracted from in conversational text.

ExtractionProviderResponseFacts

data class ExtractionProviderResponseFacts constructor(val responseModel: String? = null, val responseId: String? = null, val finishReason: String? = null, val systemFingerprint: String? = null)

What the provider said about its own response.

ExtractionReplayFidelity

enum ExtractionReplayFidelity : Enum<ExtractionReplayFidelity>

How much of a run someone could set up again from what the run recorded.

ExtractionRequest

data class ExtractionRequest constructor(val sourceLocator: SourceLocator? = null, val sourceRevision: SourceRevisionRef? = null, val profile: ExtractionContentProfileRef? = null, val currentRun: ExtractionRunRef? = null)

What a caller wants to say about one extraction, on top of the text and the user it belongs to.

ExtractionRequestedModelConfig

data class ExtractionRequestedModelConfig constructor(val modelRole: String? = null, val requestedModel: String? = null, val temperature: Double? = null, val topP: Double? = null, val topK: Int? = null, val maxTokens: Int? = null, val presencePenalty: Double? = null, val frequencyPenalty: Double? = null, val thinkingFingerprint: String? = null, val selectionFingerprint: String? = null, val timeout: Duration? = null)

What the run asked for.

ExtractionRequestRef

class ExtractionRequestRef(val token: String) : ExtractionOpaqueRef

Names the inbound request the run was started for.

ExtractionRun

class ExtractionRun constructor(val contextId: <Error class: unknown class>, val lineage: ExtractionRunLineage, val status: ExtractionRunStatus, val startedAt: Instant, val finishedAt: Instant? = null, val profile: ExtractionContentProfileRef? = null, sourceRevisions: List<SourceRevisionRef> = emptyList(), val fingerprints: ExtractionRunFingerprints = ExtractionRunFingerprints(), val runtime: ExtractionRuntimeIdentity = ExtractionRuntimeIdentity(), val requestedModel: ExtractionRequestedModelConfig? = null, val subjectRefs: ExtractionRunSubjectRefs = ExtractionRunSubjectRefs(), val experimentRef: ExtractionExperimentRef? = null, val cohortRef: ExtractionCohortRef? = null, val replayFidelity: ExtractionReplayFidelity = ExtractionReplayFidelity.NONE, val counts: ExtractionRunCounts = ExtractionRunCounts(), invocations: List<ExtractionInvocationRecord> = emptyList(), failures: List<ExtractionFailure> = emptyList(), val version: Long = 0)

The durable record of one extraction execution.

ExtractionRunConflictException

class ExtractionRunConflictException(val key: ExtractionRunKey, message: String) : RuntimeException

A write disagreed with what the store already holds.

ExtractionRunCounts

data class ExtractionRunCounts constructor(val sourcesRead: Int = 0, val chunksProcessed: Int = 0, val propositionsExtracted: Int = 0, val propositionsPersisted: Int = 0, val propositionsRejected: Int = 0, val entitiesResolved: Int = 0)

How much a run got through.

ExtractionRunFingerprint

object ExtractionRunFingerprint

The digest a store compares two terminal writes by.

ExtractionRunFingerprints

data class ExtractionRunFingerprints constructor(val promptTemplateFingerprint: String? = null, val schemaFingerprint: String? = null, val metamodelFingerprint: String? = null)

The digests that say what a run ran against.

ExtractionRunKey

data class ExtractionRunKey(val contextId: <Error class: unknown class>, val runRef: ExtractionRunRef)

Identifies one run inside one tenant.

ExtractionRunLimits

object ExtractionRunLimits

Every bound an extraction run obeys, in one place.

ExtractionRunLineage

data class ExtractionRunLineage

Where a run sits among the runs around it: its own reference, its parent, its root, what it supersedes, and which pass it is.

ExtractionRunNotFoundException

class ExtractionRunNotFoundException(val key: ExtractionRunKey) : RuntimeException

A write named a run the store does not hold.

ExtractionRunRef

data class ExtractionRunRef(val runId: String)

Names one extraction run.

ExtractionRunStatus

enum ExtractionRunStatus : Enum<ExtractionRunStatus>

Where an extraction run stands.

ExtractionRunStore

interface ExtractionRunStore

Durable store of extraction runs, and the lifecycle state machine that governs them.

ExtractionRunSubjectRefs

data class ExtractionRunSubjectRefs constructor(val actor: ExtractionActorRef? = null, val request: ExtractionRequestRef? = null, val session: ExtractionSessionRef? = null, val personalization: ExtractionPersonalizationRef? = null, val deployment: ExtractionDeploymentRef? = null)

The five pseudonymous references a run carries about whose work it was.

ExtractionRuntimeIdentity

data class ExtractionRuntimeIdentity constructor(val extractor: String? = null, val extractorVersion: String? = null, val hostApplication: String? = null, val runtime: String? = null, val runtimeVersion: String? = null)

What code ran the run, and where.

ExtractionRunTransition

class ExtractionRunTransition constructor(val status: ExtractionRunStatus, val finishedAt: Instant, val counts: ExtractionRunCounts? = null, failures: List<ExtractionFailure>? = null)

One terminal write against a run: the state it ends in, when it ended, and the counts and failures that go with it.

ExtractionRunTransitionOutcome

enum ExtractionRunTransitionOutcome : Enum<ExtractionRunTransitionOutcome>

Whether a terminal write did the work or found it already done.

ExtractionRunTransitionResult

data class ExtractionRunTransitionResult(val run: ExtractionRun, val outcome: ExtractionRunTransitionOutcome)

What a terminal write returned: the run in its terminal state, and whether this call is what put it there.

ExtractionSessionRef

class ExtractionSessionRef(val token: String) : ExtractionOpaqueRef

Names the conversation or session the material came from.

IncrementalPropositionExtraction

open class IncrementalPropositionExtraction constructor(propositionPipeline: PropositionPipeline, chunkHistoryStore: ChunkHistoryStore, dataDictionary: <Error class: unknown class>, relations: Relations, propositionRepository: PropositionRepository, entityRepository: <Error class: unknown class>, entityResolver: EntityResolver, graphProjectionService: GraphProjectionService, properties: PropositionExtractionProperties, contextIdProvider: Function<<Error class: unknown class>, String> = Function { it.id }, promptVariablesProvider: Function<<Error class: unknown class>, Map<String, Any>> = Function { emptyMap() }, extraKnownEntitiesProvider: (<Error class: unknown class>, String) -> List<<Error class: unknown class>> = { _, _ -> emptyList() }, groundingWiringService: GroundingWiringService? = null, currentUserAliasesProvider: (<Error class: unknown class>) -> List<String> = { _ -> emptyList() }, mintNewEntitiesDefault: Boolean = false, mintedEntityPropertiesProvider: (<Error class: unknown class>) -> Map<String, Any> = { _ -> emptyMap() })

Generic async proposition extraction from incremental sources (conversations, message streams, etc.). Uses IncrementalAnalyzer for windowed, deduplicated processing.

InMemoryExtractionRunStore

class InMemoryExtractionRunStore constructor(listener: DiceEventListener = DiceEventListener.DEV_NULL, maxRuns: Int) : ExtractionRunStore

Reference ExtractionRunStore that keeps runs in a map.

InMemoryPropositionRunLinkStore

class InMemoryPropositionRunLinkStore constructor(runStore: ExtractionRunStore, propositionStore: PropositionStore, maxRuns: Int) : PropositionRunLinkStore

Reference PropositionRunLinkStore that keeps the relation in a map.

LineageFailurePolicy

enum LineageFailurePolicy : Enum<LineageFailurePolicy>

What happens when a run's lineage cannot be written.

LineageNotRecordedException

class LineageNotRecordedException(val key: ExtractionRunKey, message: String, cause: Throwable? = null) : RuntimeException

A run's lineage could not be recorded, under LineageFailurePolicy.STRICT.

LlmPropositionExtractor

data class LlmPropositionExtractor(llmOptions: <Error class: unknown class>, ai: <Error class: unknown class>, template: String = "dice/extract_propositions", examples: List<<Error class: unknown class><PropositionsResult>> = emptyList(), val schemaAdherence: SchemaAdherence = SchemaAdherence.DEFAULT, val existingPropositionsToShow: Int = 100, propositionRepository: PropositionRepository? = null, val perspective: ExtractionPerspective = ExtractionPerspective.ALL) : PropositionExtractor, ExtractionConfig

LLM-based proposition extractor. Uses a Jinja template to extract propositions from chunks.

PropositionExtractionProperties

data class PropositionExtractionProperties(val enabled: Boolean = true, val extractionLlm: <Error class: unknown class>? = null, val entityResolutionLlm: <Error class: unknown class>? = null, val windowSize: Int = 10, val overlapSize: Int = 2, val triggerInterval: Int = 6, val showPrompts: Boolean = false, val showResponses: Boolean = false, val entityPackages: List<String> = emptyList(), val existingPropositionsToShow: Int = 100, val classifyBatchSize: Int = 15, val classifyLlm: <Error class: unknown class>? = null, val projectionLlm: <Error class: unknown class>? = null)

Shared configuration for proposition extraction from conversations. Used by any application integrating the DICE memory pipeline.

PropositionRunLinkScopeException

class PropositionRunLinkScopeException(val key: ExtractionRunKey, val propositionIds: List<String>) : RuntimeException

A link named a proposition the run's tenant does not hold.

PropositionRunLinkStore

interface PropositionRunLinkStore

Which extraction runs produced which claims.

PropositionsResult

data class PropositionsResult(val propositions: List<SuggestedProposition>)

Class for parsing LLM output.

ProtectedContentRef

interface ProtectedContentRef

The shape of a reference to failure material a host keeps for itself. Specification only.

TemplateModel

data class TemplateModel(val context: SourceAnalysisContext, val chunk: <Error class: unknown class>, val schemaAdherence: SchemaAdherence, val existingPropositions: List<Proposition>, val perspective: ExtractionPerspective = ExtractionPerspective.ALL) : ExtractionConfig

Model passed to the Jinja template for proposition extraction.